package com.example.receive.service;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

@Service
public class RabbitmqFanoutConsume {

    @RabbitListener(queues = "sms_fanout_queue")
    public void smsFanoutQueue(String val){
        System.out.println("smsFanoutQueue "+val);
    }

    @RabbitListener(queues = "email_fanout_queue")
    public void emailFanoutQueue(String val){
        System.out.println("emailFanoutQueue "+val);
    }

    @RabbitListener(queues = "wechat_fanout_queue")
    public void wechatFanoutQueue(String val){
        System.out.println("wechatFanoutQueue "+val);
    }
}
